type google.golang.org/grpc.acBalancerWrapper
14 uses
google.golang.org/grpc (current package)
balancer_conn_wrappers.go#L106: acbw *acBalancerWrapper
balancer_conn_wrappers.go#L288: func (ccb *ccBalancerWrapper) handleRemoveSubConn(acbw *acBalancerWrapper) {
balancer_conn_wrappers.go#L311: acbw := &acBalancerWrapper{ac: ac, producers: make(map[balancer.ProducerBuilder]*refCountedProducer)}
balancer_conn_wrappers.go#L329: acbw, ok := sc.(*acBalancerWrapper)
balancer_conn_wrappers.go#L337: acbw, ok := sc.(*acBalancerWrapper)
balancer_conn_wrappers.go#L364: type acBalancerWrapper struct {
balancer_conn_wrappers.go#L370: func (acbw *acBalancerWrapper) UpdateAddresses(addrs []resolver.Address) {
balancer_conn_wrappers.go#L410: func (acbw *acBalancerWrapper) Connect() {
balancer_conn_wrappers.go#L416: func (acbw *acBalancerWrapper) getAddrConn() *addrConn {
balancer_conn_wrappers.go#L426: func (acbw *acBalancerWrapper) NewStream(ctx context.Context, desc *StreamDesc, method string, opts ...CallOption) (ClientStream, error) {
balancer_conn_wrappers.go#L436: func (acbw *acBalancerWrapper) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...CallOption) error {
balancer_conn_wrappers.go#L453: func (acbw *acBalancerWrapper) GetOrBuildProducer(pb balancer.ProducerBuilder) (balancer.Producer, func()) {
picker_wrapper.go#L66: func doneChannelzWrapper(acw *acBalancerWrapper, result *balancer.PickResult) {
picker_wrapper.go#L155: acw, ok := pickResult.SubConn.(*acBalancerWrapper)